package com.zhou.common.mybatis.template.shiro;

import org.reactivestreams.Subscription;

import reactor.core.publisher.BaseSubscriber;

public class SampleSubscriber<T> extends BaseSubscriber<T> {

    public void hookOnSubscribe(Subscription subscription) {
        System.out.println("Subscribed");
        request(3);
    }

    public void hookOnNext(T value) {
        System.out.println(value);
        request(2);
    }
}